Skip to content

DPL raw proxy: Supporting message sequences/pruned headers#7914

Merged
matthiasrichter merged 3 commits into
AliceO2Group:devfrom
matthiasrichter:dev-ExternalFairMQDeviceProxy
Jan 8, 2022
Merged

DPL raw proxy: Supporting message sequences/pruned headers#7914
matthiasrichter merged 3 commits into
AliceO2Group:devfrom
matthiasrichter:dev-ExternalFairMQDeviceProxy

Conversation

@matthiasrichter

Copy link
Copy Markdown
Collaborator

This is following up to #7110 and O2 1325

More tests are ongoing right now and there is an issue with the message forwarding in the output proxy.

@matthiasrichter matthiasrichter requested a review from a team as a code owner January 6, 2022 08:38
Comment thread Framework/Core/include/Framework/ExternalFairMQDeviceProxy.h Outdated

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I would invert the logic and have a continue on channelName.empty() == true.

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ah, yeah, can revise the logic. Actually I did not want to continue in the loop because the unmatched specs are logged. But I will combine this, there is room for cleanup in the logic.

This is also simplifying the message processing loop to avoid repeated
query matching for split payload message pairs.

Extending configuration of DPL injector function, but new configuration
features like `paranoid` checking of message consistency still need to be
implemented. Time consuming consistency checks are will be optional.
Having now a flexible message generation to test both split payload
pair messages as well as payload sequences with one preceding header.

Randomized test packages and enhanced check on the consumer side.
Message mode is randomly selected per event.
The output proxy is not yet supporting forwarding of neither message pairs
nor sequences, this needs to be investigated. Looks like not all parts are
forwarded. The output proxy is based on message forwarding in the core
framework DataProcessingDevice

[480102:checker]: [08:58:09][ERROR] inconsistent number of inputs extracted
[480102:checker]: [08:58:09][ERROR] inconsistent number of inputs extracted
[480102:checker]: [08:58:09][ERROR] Header is not a DataHeader?
[480102:checker]: [08:58:09][INFO] 1 input slots(s), data 0, parts 6, mode 1
[480102:checker]: [08:58:09][FATAL] Test condition "data == *counter" failed
@matthiasrichter matthiasrichter force-pushed the dev-ExternalFairMQDeviceProxy branch from fc6452f to 71707de Compare January 7, 2022 20:13
@matthiasrichter matthiasrichter changed the title WIP: DPL raw proxy: Supporting message sequences/pruned headers DPL raw proxy: Supporting message sequences/pruned headers Jan 8, 2022
@matthiasrichter

Copy link
Copy Markdown
Collaborator Author

I think we simply go on with that now and I'm solving the minor cleanups in subsequent commits.

@matthiasrichter matthiasrichter merged commit a3a8ce4 into AliceO2Group:dev Jan 8, 2022
@ktf

ktf commented Jan 8, 2022

Copy link
Copy Markdown
Member

Yes, sure. Thank you for the contribution.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Development

Successfully merging this pull request may close these issues.

2 participants